package com.ruoyi.framework.mqtt.handler;

import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.MessagingException;
import org.springframework.stereotype.Component;

/**
 * @author Taney
 */
@Component
public class MsgHandler extends AbstractHandler  {

    @Override
    public void handleMessage(Message message, String topic, String msg) throws MessagingException {
//        logger.info("===Received log【 Msg(topic： {}): {}】", topic, msg);
        //MessageHeaders headers = message.getHeaders();
        //TODO 可以选择将消息保存到本地
    }
}
